00f1014873a10ca800f6c9efdfdb12a82a09c8ee,components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java,CassandraAggregationRepository,initSelectKeyIdStatement,#,274
Before Change
// -------------------------------------------------------------------------
private void initSelectKeyIdStatement() {
String cql = generateSelect(table,
new String[]{getKeyColumn(), exchangeIdColumn}, // Key + Exchange Id columns
pkColumns, pkColumns.length - 1).toString(); // Where fixed PK columns
LOGGER.debug("Generated Select keys {}", cql);
selectKeyIdStatement = applyConsistencyLevel(getSession().prepare(cql), readConsistencyLevel);
}
protected List<Row> selectKeyIds() {
After Change
// -------------------------------------------------------------------------
private void initSelectKeyIdStatement() {
Select select = generateSelect(table,
new String[]{getKeyColumn(), exchangeIdColumn}, // Key + Exchange Id columns
pkColumns, pkColumns.length - 1); // Where fixed PK columns
select = applyConsistencyLevel(select, readConsistencyLevel);
LOGGER.debug("Generated Select keys {}", select);
selectKeyIdStatement = getSession().prepare(select);
}
protected List<Row> selectKeyIds() {